package com.bage.finance.biz.service;

import com.bage.finance.biz.domain.MqMsg;

public interface MqMsgService {
    /**
     * 通过定时任务处理消息
     */
    void handleMqMessage();

    /**
     * 保存mq消息
     * @param mqMsg
     */
    boolean create(MqMsg mqMsg);

    /**
     * MQ消费消息成功
     * @param mqMsg
     */
    boolean success(MqMsg mqMsg);

    /**
     * MQ消费消息失败
     * @param mqMsg
     * @return
     */
    boolean fail(MqMsg mqMsg);

    /**
     * 获取MQ消息
     * @param requestId
     * @return
     */
    MqMsg get(String requestId);
}
